import { NextRequest, NextResponse } from "next/server";
import { z } from "zod";
import { assertSameOrigin, requireUser } from "@/lib/auth/session";
import { getThread, reply, setInquiryStatus } from "@/lib/inquiries/service";
import { handle, parseBody } from "@/lib/api";
export const dynamic = "force-dynamic";
type P = { params: Promise<{ id: string }> };
export async function GET(_req: NextRequest, { params }: P) { try { const u = await requireUser(); const { id } = await params; return NextResponse.json(await getThread(id, u.id)); } catch (e) { return handle(e); } }
const Body = z.object({ body: z.string().trim().min(1).max(3000), idempotencyKey: z.string().max(80).optional() });
export async function POST(req: NextRequest, { params }: P) { try { await assertSameOrigin(); const u = await requireUser(); const { id } = await params; const b = await parseBody(req, Body); const m = await reply(id, u.id, b.body, b.idempotencyKey); return NextResponse.json({ ok: true, message: m }, { status: 201 }); } catch (e) { return handle(e); } }
const Patch = z.object({ status: z.enum(["OPEN", "ARCHIVED", "BLOCKED"]) });
export async function PATCH(req: NextRequest, { params }: P) { try { await assertSameOrigin(); const u = await requireUser(); const { id } = await params; const b = await parseBody(req, Patch); await setInquiryStatus(id, u.id, b.status); return NextResponse.json({ ok: true }); } catch (e) { return handle(e); } }